org.springframework.web.reactive.socket.adapter

Class JettyWebSocketSession

java.lang.Object

org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession<T>

org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession<Session>

org.springframework.web.reactive.socket.adapter.JettyWebSocketSession

All Implemented Interfaces:

WebSocketSession

public class JettyWebSocketSession
extends AbstractListenerWebSocketSession<Session>

Spring WebSocketSession implementation that adapts to a Jetty WebSocket org.eclipse.jetty.websocket.api.Session.

Since:

5.0

Author:

Violeta Georgieva, Rossen Stoyanchev

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	JettyWebSocketSession.SendProcessorCallback

Nested classes/interfaces inherited from class org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession

AbstractListenerWebSocketSession.WebSocketSendProcessor

Field Summary

Fields

Modifier and Type	Field and Description
private SuspendToken	suspendToken

Constructor Summary

Constructors

Constructor and Description
JettyWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory)
JettyWebSocketSession(Session session, HandshakeInfo info, DataBufferFactory factory, <any> completionMono)

Method Summary

Modifier and Type	Method and Description
protected boolean	canSuspendReceiving() Whether the underlying WebSocket API has flow control and can suspend and resume the receiving of messages.
<any>	close(CloseStatus status) Close the WebSocket session with the given status.
protected void	resumeReceiving() Resume receiving new message(s) after demand is generated by the downstream Subscriber.
protected boolean	sendMessage(WebSocketMessage message) Send the given WebSocket message.
protected void	suspendReceiving() Suspend receiving until received message(s) are processed and more demand is generated by the downstream Subscriber.

Methods inherited from class org.springframework.web.reactive.socket.adapter.AbstractListenerWebSocketSession

getSendProcessor, handleClose, handleError, handleMessage, onComplete, onError, onNext, onSubscribe, receive, send

Methods inherited from class org.springframework.web.reactive.socket.adapter.AbstractWebSocketSession

binaryMessage, bufferFactory, getDelegate, getHandshakeInfo, getId, pingMessage, pongMessage, textMessage, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.web.reactive.socket.WebSocketSession

close

Field Detail

suspendToken

@Nullable
private volatile SuspendToken suspendToken

Constructor Detail

JettyWebSocketSession

public JettyWebSocketSession(Session session,
                             HandshakeInfo info,
                             DataBufferFactory factory)

JettyWebSocketSession

public JettyWebSocketSession(Session session,
                             HandshakeInfo info,
                             DataBufferFactory factory,
                             @Nullable
                             <any> completionMono)

Method Detail

canSuspendReceiving

protected boolean canSuspendReceiving()

Description copied from class: AbstractListenerWebSocketSession

Whether the underlying WebSocket API has flow control and can suspend and resume the receiving of messages.

Specified by:

canSuspendReceiving in class AbstractListenerWebSocketSession<Session>

suspendReceiving

protected void suspendReceiving()

Description copied from class: AbstractListenerWebSocketSession

Suspend receiving until received message(s) are processed and more demand is generated by the downstream Subscriber.

Note: if the underlying WebSocket API does not provide flow control for receiving messages, and this method should be a no-op and AbstractListenerWebSocketSession.canSuspendReceiving() should return false.

Specified by:

suspendReceiving in class AbstractListenerWebSocketSession<Session>

resumeReceiving

protected void resumeReceiving()

Description copied from class: AbstractListenerWebSocketSession

Resume receiving new message(s) after demand is generated by the downstream Subscriber.

Note: if the underlying WebSocket API does not provide flow control for receiving messages, and this method should be a no-op and AbstractListenerWebSocketSession.canSuspendReceiving() should return false.

Specified by:

resumeReceiving in class AbstractListenerWebSocketSession<Session>

sendMessage

protected boolean sendMessage(WebSocketMessage message)
                       throws java.io.IOException

Description copied from class: AbstractListenerWebSocketSession

Send the given WebSocket message.

Specified by:

sendMessage in class AbstractListenerWebSocketSession<Session>

Throws:

java.io.IOException

close

public <any> close(CloseStatus status)

Description copied from interface: WebSocketSession

Close the WebSocket session with the given status.

Parameters:

status - the close status